Node / mirrors / RTNode-HeltecV4 / files / tests / test_tcp_framing.py

Displaying Raw • Download

Tff7b72import T7ee787socket

Tff7b72import T7ee787time

Tff7b72def Td2a8ff_wait_for_logTb4b4b4(Te6edf3rtnodeTb4b4b4, Te6edf3patternTb4b4b4: Tffa657strTb4b4b4, Te6edf3sinceTb4b4b4: Tffa657floatTb4b4b4, Te6edf3timeoutTb4b4b4: Tffa657float Tff7b72= T79c0ff5.0Tb4b4b4) Tff7b72-Tff7b72> Tffa657str Tff7b72| Tff7b72NoneTb4b4b4:

Te6edf3deadline Tff7b72= Te6edf3timeTff7b72.Td2a8ffmonotonicTb4b4b4(Tb4b4b4) Tff7b72+ Te6edf3timeout

Te6edf3pattern Tff7b72= Te6edf3patternTff7b72.Td2a8fflowerTb4b4b4(Tb4b4b4)

Tff7b72while Te6edf3timeTff7b72.Td2a8ffmonotonicTb4b4b4(Tb4b4b4) Tff7b72< Te6edf3deadlineTb4b4b4:

Tff7b72for Te6edf3lineTb4b4b4, Te6edf3timestamp Tff7b72in Te6edf3rtnodeTff7b72.Td2a8fflog_linesTb4b4b4:

Tff7b72if Te6edf3timestamp Tff7b72>Tff7b72= Te6edf3since Tff7b72and Te6edf3pattern Tff7b72in Te6edf3lineTff7b72.Td2a8fflowerTb4b4b4(Tb4b4b4)Tb4b4b4:

Tff7b72return Te6edf3line

Te6edf3timeTff7b72.Td2a8ffsleepTb4b4b4(T79c0ff0.02Tb4b4b4)

Tff7b72return Tff7b72None

Tff7b72def Td2a8fftest_tcp_server_detects_hdlc_and_kiss_per_clientTb4b4b4(Te6edf3rtnodeTb4b4b4, Te6edf3rtnode_tcp_endpointTb4b4b4)Tb4b4b4:

Te6edf3hostTb4b4b4, Te6edf3port Tff7b72= Te6edf3rtnode_tcp_endpoint

Tff7b72assert Te6edf3_wait_for_logTb4b4b4(Te6edf3rtnodeTb4b4b4, Ta5d6fffTa5d6ff"Ta5d6ffServer listening on port Tffd700{Te6edf3portTffd700}Ta5d6ff"Tb4b4b4, T79c0ff0Tb4b4b4, Te6edf3timeoutTff7b72=T79c0ff15.0Tb4b4b4)Tb4b4b4, Tb4b4b4(

Ta5d6ff"Ta5d6ffRTNode TCP server did not become readyTa5d6ff"

Tb4b4b4)

Tff7b72for Te6edf3delimiterTb4b4b4, Te6edf3expected Tff7b72in Tb4b4b4(Tb4b4b4(Ta5d6ffbTa5d6ff"Tffea00\x7eTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffframing: HDLCTa5d6ff"Tb4b4b4)Tb4b4b4, Tb4b4b4(Ta5d6ffbTa5d6ff"Tffea00\xc0Ta5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffframing: KISSTa5d6ff"Tb4b4b4)Tb4b4b4)Tb4b4b4:

Tff7b72with Te6edf3socketTff7b72.Td2a8ffcreate_connectionTb4b4b4(Tb4b4b4(Te6edf3hostTb4b4b4, Te6edf3portTb4b4b4)Tb4b4b4, Te6edf3timeoutTff7b72=T79c0ff5.0Tb4b4b4) Tff7b72as Te6edf3clientTb4b4b4:

Te6edf3started Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)

Te6edf3clientTff7b72.Td2a8ffsendallTb4b4b4(Te6edf3delimiterTb4b4b4)

Tff7b72assert Te6edf3_wait_for_logTb4b4b4(Te6edf3rtnodeTb4b4b4, Te6edf3expectedTb4b4b4, Te6edf3startedTb4b4b4)Tb4b4b4, Tb4b4b4(

Ta5d6fffTa5d6ff"Ta5d6ffRTNode did not detect Tffd700{Te6edf3expectedTffd700}Ta5d6ff from first delimiterTa5d6ff"

Tb4b4b4)